package xginxnsq

import (
	"gitee.com/xiaoyutab/xgotool/optional/xnsq"
	"gitee.com/xiaoyutab/xgotool/xgin"
	"github.com/gin-gonic/gin"
)

// 启动NSQ队列【根据配置的NSQ地址进行启动】
//
//	POST	start
func start(c *gin.Context) *xgin.Response {
	type temp struct {
		Set string `json:"set" form:"set"` // 设置的NSQ队列地址
		Get string `json:"get" form:"get"` // 获取的NSQ队列地址
	}
	t := temp{}
	if err := xgin.Bind(c, &t); err != nil {
		return xgin.Resp().Error(err)
	}
	var err error
	if t.Get != "" {
		err = xnsq.Start(t.Get, t.Set)
	} else {
		err = xnsq.Startx()
	}
	if err != nil {
		return xgin.Resp().Error(err)
	}
	return xgin.Resp().SuccessEmpty()
}
